package com.senchen.rabbitconfig;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;


/**
 * 功能: 一句话简要概括功能
 * 作者: 小静VS静
 * 时间: 2020-10-31
 * 逻辑:TODO 在这里描述功能的大体逻辑
 * 版本:1.0
 * 修订:
 */
@Component()
public class Consumer {
    //通过监听这个队列  判断是否有消息 并且将其消费
    @RabbitListener(queues = "testqueueone")
    public void getMessage(Message message){
        //消费的方法Message 用的是amqp.core的的方法
        System.out.println(">>>>>>>>>one已经被消费"+ new String(message.getBody()));

    }
}
